package com.pine.dcts.core.channel;

import com.alibaba.datax.common.element.Record;
import com.alibaba.datax.common.util.Configuration;
import com.alibaba.datax.core.transport.channel.Channel;

import java.util.Collection;

public class RedisChannel extends Channel {

    public RedisChannel(Configuration configuration) {
        super(configuration);
    }

    @Override
    protected void doPush(Record record) {

    }

    @Override
    protected void doPushAll(Collection<Record> collection) {

    }

    @Override
    protected Record doPull() {
        return null;
    }

    @Override
    protected void doPullAll(Collection<Record> collection) {

    }

    @Override
    public int size() {
        return 0;
    }

    @Override
    public boolean isEmpty() {
        return false;
    }

    @Override
    public void clear() {

    }
}
